package com.dx.logic.controller;

import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.RestController;

/**
 * todo
 *
 * @author xufeng
 * @since 06.04.2023
 */
@Slf4j
@RestController
public class TestController {

//    @Resource
//    private KafkaTemplate<String, Object> kafkaTemplate;
//
//    @PostMapping()
//    @ResponseBody
//    public String hello(@RequestBody Map<String,Object> map) {
//        log.info("zz");
//       return "服务A";
//    }
//
//    @PostMapping("/send")
//    @ResponseBody
//    public void send(String msg) {
//        KafkaMessageVo messageDto = new KafkaMessageVo();
//        messageDto.setId(UUID.randomUUID().toString());
//        for (int i=0;i<=10; i++){
//            messageDto.setMsg(msg);
//            kafkaTemplate.send("kafka4" ,messageDto);
//
//        }
//    }
}
